package net.sh.dpinfrastructure.support.spring.configuration;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;
import org.springframework.context.annotation.Primary;

import net.sh.dpinfrastructure.message.DPMessage;
import net.sh.dpinfrastructure.message.DPRedisMessage;
import redis.clients.jedis.JedisPool;

/**
 * 
 * 消息队列配置类
 * 
 * @version 1.0
 * @since JDK1.7
 * @author shaohui
 * @company 上海朝阳永续信息技术有限公司
 * @copyright (c) 2016 SunTime Co'Ltd Inc. All rights reserved.
 * @date 2016年8月8日 下午2:40:06
 */
@Configuration
@Import(DPRedisCacheConfiguration.class)
public class DPRedisMessageConfiguration {

    /**
     * 
     * 配置基于redis实现的消息队列（简单消息队列）
     *
     * @param logger
     * @param jedisPool
     * @return
     * 
     * @author shaohui
     * @date 2016年8月8日 下午2:43:24
     */
    @Bean("redis")
    @Primary
    public DPMessage getDPRedisMessage(JedisPool jedisPool) {
        return new DPRedisMessage(jedisPool);
    }
}
